今天来和小伙伴们聊一聊该如何处理 gRPC 中遇到的异常。

在之前的几篇文章中，其实我们也遇到过异常问题，只是当时没有和小伙伴们细说，只是囫囵吞枣写了一个案例而已，今天我们就来把这个话题跟小伙伴们仔细捋一捋。

我们之前写过一个登录的案例，在之前的案例中，如果用户在登录时输入了错误的用户名密码的话，那么我们是通过一个普通的数据流返回异常信息，其实，对于异常信息，我们可以通过专门的异常通道来写回到客户端。

先来看看服务端如何处理异常。

还是以我们之前的 gRPC 登录案例为例，我们修改服务端的登录逻辑如下（完整代码小伙伴们可以参考之前的 手把手教大家在 gRPC 中使用 JWT 完成身份校验 一文）：

小伙伴们看到，在登录失败时我们通过 responseObserver.onError 方法将异常信息写回到客户端。这个方法的参数是一个 Throwable 对象，对于这个对象，在 Status 这个枚举类中定义了一些常见的值，分别如下：

系统默认给出的请求类型大致上就这些。当然，如果这些并不能满足你的需求，我们也可以扩展这个枚举类。

当服务端给出异常信息之后，客户端的处理分为两种情况。

如果客户端是异步请求，则直接在异常回调中处理即可，如下：

@Override public void onError(Throwable throwable) { System.out.println("throwable = " + throwable); }

@Override public void onCompleted() { countDownLatch.countDown(); } }); countDownLatch.await(); }}

小伙伴们看到，直接在 onError 回到中处理异常即可。

如果客户端请求是同步阻塞请求，那么就要通过异常捕获的方式获取服务端返回的异常信息了，如下：

private static void login(LoginServiceGrpc.LoginServiceBlockingStub stub) throws InterruptedException { try { LoginResponse resp = stub.login(LoginBody.newBuilder().setUsername("javaboy").setPassword("1234").build()); System.out.println("resp.getToken() = " + resp.getToken()); } catch (Exception e) { System.out.println("e.getMessage() = " + e.getMessage()); } }}

同步阻塞请求就通过异常捕获去获取服务端返回的异常信息即可。

最后，再来和小伙伴们说一个提高 gRPC 数据传输效率的小技巧，那就是传输的数据可以使用 gzip 进行压缩。

具体处理方式就是在客户端调用 withCompression 方法指定数据压缩，如下：

private static void login(LoginServiceGrpc.LoginServiceBlockingStub stub) throws InterruptedException { try { LoginResponse resp = stub.withCompression("gzip").login(LoginBody.newBuilder().setUsername("javaboy").setPassword("123").build()); System.out.println("resp.getToken() = " + resp.getToken()); } catch (Exception e) { System.out.println("e.getMessage() = " + e.getMessage()); } }}

好啦，一个关于 gRPC 的小小知识点～